package sf.r2dbc.sql;

import io.r2dbc.spi.Result;
import reactor.core.publisher.Flux;


/**
 * 结果集回调处理
 */
public interface R2dbcResultSetCallback<T> {
    /**
     * @param resultFlux
     * @return
     */
    Flux<T> callback(Flux<Result> resultFlux);
}
